//1. 引入mysql模块
const mysql = require("mysql");
//2. 创建连接池对象
const pool = mysql.createPool({
    host: "127.0.0.1",
    user: "root",
    password: "root",
    database: "meibang",
    port: 3306
})
const exec = (sql, params) => {
    //3封装一个exec函数,在函数内部返回一个promise对象
    return new Promise(function (resolve, reject) {
        //conn 链接对象
        //4.从连接池对象里获取链接对象
        pool.getConnection((err, conn) => {
            if (err) {
                console.log("连接数据库失败!" + err);
                reject(err)
            }
            //5. 通过链接对象,执行sql语句,获取结果
            conn.query(sql, params, (err, result) => {
                if (err) {
                    console.log("执行sql语句失败!" + err);
                    reject(err)
                }
                resolve(result);
                //6. 释放链接
                conn.release();
            })
        })
    })
}

//7.暴露 exec函数
module.exports = {
    exec
}